package app

import bean.ResumeMatchData
import common.TApp
import controller.PositionLanguageMatchController
import org.apache.spark.streaming.dstream.DStream
import handler.JobMatchDataHandler

object PositionLanguageMatchRealTimeApp extends TApp {
  val controller = new PositionLanguageMatchController()
  start(appName = "PositionLanguageMatchRealTimeApp") {
    val resumeData: DStream[ResumeMatchData] = PositionLanguageMatchHandler.kafkaResumeDataHandler("BD1", "ITproject")
    controller.dispatch(resumeData)
    JobMatchDataHandler.startAndAwait()
  }
}